package com.pai4j.common.service.messagequeue.local;

import java.util.List;
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;

public class AbstractArrayBlockQueue<M> extends AbstractLocalQueue<ArrayBlockingQueue, M> {

    @Override
    protected Queue<M> queue() {
        return null;
    }

    @Override
    protected boolean consume(M message) {
        return false;
    }

    @Override
    public boolean doReject(List<M> messages) {
        return false;
    }
}
